from celery import Celery
import os

# 1 配置可能用到的项目环境
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 2 实例化一个Celery对象("对象名字")
app = Celery('celery_tasks')

# 3 加载config文件中的配置
app.config_from_object('libs.celery_tasks.config')

# 4.自动注册celery任务
app.autodiscover_tasks(['libs.celery_tasks.sendmsg',
                        'libs.celery_tasks.sendemail',
                        'libs.celery_tasks.generate_detail_html'])

# 启动worker的命令 celery -A libs.celery_tasks.main worker -l info
#   -A指对应的应用程序, 其参数是项目中 Celery实例的位置。
#   worker指这里要启动的worker。
#   -l指日志等级，比如info等级。
